package com.aos.iot.socket.common.store;


import com.aos.iot.socket.common.message.Message;
import com.aos.iot.socket.common.store.pubsub.PubSubStore;

public interface StoreFactory<M extends Message> {

    PubSubStore<M> pubSubStore();

    Store createStore(String channelId);

    void shutdown();
}
